package com.atguigu.flink.source;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class SubmitAsyncTest {

    public static void main(String[] args) throws Exception {

        // TODO 1.指定流环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // TODO 2.从指定端口读取数据
        // TODO 3.指定输出
        env.socketTextStream("hadoop102" , 8888).print();

        // TODO 4.指定同步执行
        //env.execute();

        // TODO 5.指定异步执行
        env.executeAsync();

        //-------------------------------------------------------------------------------------

        // TODO 1.指定流环境
        StreamExecutionEnvironment env1 = StreamExecutionEnvironment.getExecutionEnvironment();

        // TODO 2.从指定端口读取数据
        // TODO 3.指定输出
        env1.socketTextStream("hadoop102" , 8889).print();

        // TODO 4.指定同步执行
        //env.execute();

        // TODO 5.指定异步执行
        env1.executeAsync();

    }
}
